type google.golang.org/grpc.acBalancerWrapper
17 uses
google.golang.org/grpc (current package)
balancer_wrapper.go#L200: acbw := &acBalancerWrapper{
balancer_wrapper.go#L217: acbw, ok := sc.(*acBalancerWrapper)
balancer_wrapper.go#L270: type acBalancerWrapper struct {
balancer_wrapper.go#L308: func (acbw *acBalancerWrapper) updateState(s connectivity.State, curAddr resolver.Address, err error) {
balancer_wrapper.go#L345: func (acbw *acBalancerWrapper) String() string {
balancer_wrapper.go#L349: func (acbw *acBalancerWrapper) UpdateAddresses(addrs []resolver.Address) {
balancer_wrapper.go#L353: func (acbw *acBalancerWrapper) Connect() {
balancer_wrapper.go#L357: func (acbw *acBalancerWrapper) Shutdown() {
balancer_wrapper.go#L365: func (acbw *acBalancerWrapper) NewStream(ctx context.Context, desc *StreamDesc, method string, opts ...CallOption) (ClientStream, error) {
balancer_wrapper.go#L376: func (acbw *acBalancerWrapper) Invoke(ctx context.Context, method string, args any, reply any, opts ...CallOption) error {
balancer_wrapper.go#L393: func (acbw *acBalancerWrapper) GetOrBuildProducer(pb balancer.ProducerBuilder) (balancer.Producer, func()) {
balancer_wrapper.go#L426: func (acbw *acBalancerWrapper) closeProducers() {
balancer_wrapper.go#L449: func (acbw *acBalancerWrapper) healthListenerRegFn() func(context.Context, func(balancer.SubConnState)) func() {
balancer_wrapper.go#L472: func (acbw *acBalancerWrapper) RegisterHealthListener(listener func(balancer.SubConnState)) {
clientconn.go#L1192: acbw *acBalancerWrapper
picker_wrapper.go#L76: func doneChannelzWrapper(acbw *acBalancerWrapper, result *balancer.PickResult) {
picker_wrapper.go#L179: acbw, ok := pickResult.SubConn.(*acBalancerWrapper)